package com.xiaoniu.mc.client.annotation;

import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

/**
 * @类描述：Xmq客户端注解类
 * @创建人：林继丰
 * @创建时间：2017/8/17 16:54
 * @版权：Copyright (c) 深圳市牛鼎丰科技有限公司-版权所有.
 */
@Retention(value = RetentionPolicy.RUNTIME)
@Target(value = {ElementType.TYPE, ElementType.METHOD})
public @interface XmqConsumer {
    //主题
    String topic();

    //标签
    String tags();

    //消费组
    String groups();

    //有序队列
    boolean isOrderLy() default false;

    //是否广播
    boolean isBroadcast() default false;

    //最小消费线程
    int minConsumerThreadSum() default 1;

    //最大消费线程
    int maxConsumerThreadSum() default 10;

    //并发处理消息数
    int batchConsumerMessage() default 1;

    //TODO 是否加密
    boolean isEncrypt() default false;

}
